package com.itheima.project.sink;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @ClassName DelaySink.java
 * @Description 延迟消息-接收消息接口
 */
public interface DelaySink {

    public static String DELAY_INPUT="delay-input";

    @Input(DELAY_INPUT)
    SubscribableChannel delayInput();

}
